package com.mq.common;

import com.mq.mqserver.core.BasicProperties;

import java.io.IOException;

/**
 * 函数式接口,回调函数,当消费者收到消息后,要处理消息,调用者通过这个接口实现具体的功能
 */
@FunctionalInterface
public interface Consumer {
    //deliver:投递的意思,这个方法在每次服务器收到发送来的消息后,调用
    //通过这个方法把消息推送给对应的消费者
    void handlerDeliver(String consumerTag, BasicProperties basicProperties,byte[] body) throws MqException, IOException;
}
